package com.example.demo.utils;

import cn.hutool.json.JSONObject;
import com.example.demo.dto.AccessTokenDto;
import com.example.demo.dto.ApprovalNoticeDto;
import org.springframework.web.client.RestTemplate;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;

public final class WxUtils {


    /**
     * 获取微信调用权限
     *
     * @return
     */
    public static String getAccessToken() {
        String secret = "197639cd0abb7be8dda8c29b819b9fda";
        String appId = "wx9c6810500b31e6bb";
        //获取access_token
//        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential" +
//                "&appid=" + appid + "&secret=" + secret;
//        String json = restTemplate.getForObject(url, String.class);
//        String accessToken = stringRedisTemplate.opsForValue().get("accessToken");
        RestTemplate httpRest = new RestTemplate();
        AccessTokenDto forObject = httpRest.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + secret, AccessTokenDto.class);
        return forObject.getAccess_token();
    }

    /**
     * 获取微信服务号调用权限
     *
     * @return
     */
    public static String getAccessToken2() {
        String secret = "f5c44dbb93f6da1dde6a5311ed07dbb1";
        String appId = "wx872e54787d72fda5";
        //获取access_token
//        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential" +
//                "&appid=" + appid + "&secret=" + secret;
//        String json = restTemplate.getForObject(url, String.class);
//        String accessToken = stringRedisTemplate.opsForValue().get("accessToken");
        RestTemplate httpRest = new RestTemplate();
        AccessTokenDto forObject = httpRest.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + secret, AccessTokenDto.class);
        return forObject.getAccess_token();
    }


    /**
     * 生成微信小程序二维码
     *
     * @param page  当前小程序相对页面 必须是已经发布的小程序存在的页面（否则报错），例如 pages/index/index, 根路径前不要填加 /,不能携带参数（参数请放在scene字段里），如果不填写这个字段，默认跳主页面
     * @param scene 最大32个可见字符，只支持数字，大小写英文以及部分特殊字符：!#$&'()*+,/:;=?@-._~，其它字符请自行编码为合法字符（因不支持%，中文无法使用 urlencode 处理，请使用其他编码方式）
     */
    //todo
    public static InputStream generateQrCode(String page, String scene) {
//        String filePath = "C/file/" + scene + ".png";
        String filePath = "C:/Users/Eric/Desktop/"+ scene + ".png";
        try {
            String accessToken = getAccessToken();
            //调用微信接口生成二维码
            URL url = new URL("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + accessToken);
            HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
            httpURLConnection.setRequestMethod("POST");// 提交模式
            // conn.setConnectTimeout(10000);//连接超时 单位毫秒
            // conn.setReadTimeout(2000);//读取超时 单位毫秒
            // 发送POST请求必须设置如下两行
            httpURLConnection.setDoOutput(true);
            httpURLConnection.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            PrintWriter printWriter = new PrintWriter(httpURLConnection.getOutputStream());
            // 发送请求参数
            JSONObject paramJson = new JSONObject();
            //这就是你二维码里携带的参数 String型  名称不可变
            paramJson.put("scene", scene);
            //注意该接口传入的是page而不是path
            paramJson.put("page", page);
            //这是设置扫描二维码后跳转的页面
            paramJson.put("width", 200);
            paramJson.put("is_hyaline", true);
            paramJson.put("auto_color", true);
            printWriter.write(paramJson.toString());
            // flush输出流的缓冲
            printWriter.flush();

            //开始获取数据
            BufferedInputStream bis = new BufferedInputStream(httpURLConnection.getInputStream());
            OutputStream os = new FileOutputStream(new File(filePath));
            int len;
            byte[] arr = new byte[1024];
            while ((len = bis.read(arr)) != -1) {
                os.write(arr, 0, len);
                os.flush();
            }
            os.close();
            return httpURLConnection.getInputStream();
        } catch (Exception e) {
            e.printStackTrace();
        }

        System.out.println("打开地址查看生成的二维码：" + filePath);
        return null;
    }


    /**
     * 微信通知接单提醒
     *
     * @param approvalNoticeDto
     */
    public static void wxApproval(ApprovalNoticeDto approvalNoticeDto) {
        JSONObject body=new JSONObject();
        body.set("touser",approvalNoticeDto.getOpenId());//openid
        body.set("template_id","QI5T0Gj2YEmIuRnKgwI5LrYaHjTrTEXihTtnltBuv1I");//模板id
        body.set("page","pages/orderDetail/orderDetail?id="+approvalNoticeDto.getId());//跳转页面
        JSONObject json=new JSONObject();
        json.set("thing4",new JSONObject().set("value","A3"));
        json.set("thing7",new JSONObject().set("value", "报修内容"));
        json.set("thing5",new JSONObject().set("value", "工程师名称"));
        //接单时间
        json.set("date2",new JSONObject().set("value","2021-06-12 12:00"));
        //订单状态
        json.set("phrase1",new JSONObject().set("value", "已接单"));
//        if(approvalNoticeDto.getResult()!=null){
//            json.set("thing8",new JSONObject().set("value",approvalNoticeDto.getRemark()));
//        }else{
//            json.set("thing8",new JSONObject().set("value","无"));
//        }

        body.set("data",json);
        //发送
        String accessToken= getAccessToken();
        String post =  cn.hutool.http.HttpUtil.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken, body.toString());
//        return "ok";
        System.out.println(post);
    }

    /**
     * 微信通知维修完成提醒
     *
     * @param approvalNoticeDto
     */
    public static void wxFinish(ApprovalNoticeDto approvalNoticeDto) {
        JSONObject body=new JSONObject();
        body.set("touser",approvalNoticeDto.getOpenId());//openid
        body.set("template_id","1FgMcwl7c31N01pMtJze8Fa_Z7tgeBvIjyhCAau_VJI");//模板id
        body.set("page","pages/orderDetail/orderDetail?id="+approvalNoticeDto.getId());//跳转页面
        JSONObject json=new JSONObject();
        json.set("thing2",new JSONObject().set("value","A3"));
//        json.set("thing7",new JSONObject().set("value", "报修内容"));
        json.set("name3",new JSONObject().set("value", "工程师名称"));
        //工程师电话
        json.set("phone_number4",new JSONObject().set("value", "13213213"));
        //完成时间
        json.set("time10",new JSONObject().set("value", "2021-10-12 23:22:21"));
        //工单内容
        json.set("thing17",new JSONObject().set("value", "工单内容"));
//        if(approvalNoticeDto.getResult()!=null){
//            json.set("thing8",new JSONObject().set("value",approvalNoticeDto.getRemark()));
//        }else{
//            json.set("thing8",new JSONObject().set("value","无"));
//        }

        body.set("data",json);
        //发送
        String accessToken= getAccessToken();
        String post =  cn.hutool.http.HttpUtil.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken, body.toString());
//        return "ok";
        System.out.println(post);
    }

}

